<template>
	<div class="center">
		<div class="live">
			<div id="dplayer"></div>
		</div>
		<div class="danmu">
			<vue-baberrage :isShow="barrageIsShow" :barrageList="barrageList" :loop="barrageLoop">
			</vue-baberrage>
		</div>
		<input type="text">
		<uni-fab :content="content" :horizontal="horizontal" :vertical="vertical" @trigger="trigger"></uni-fab>
		<view>
			<view class="tips color_fff size_12 align_c" :class="{ 'show':ajax.loading }" @tap="getHistoryMsg">{{ajax.loadText}}</view>
			<view class="box-1" id="list-box">
				<view class="talk-list">
					<view v-for="(item,index) in talkList" :key="index" :id="`msg-${item.id}`">
						<view class="item flex_col" :class=" item.type == 1 ? 'push':'pull' ">
							<image :src="item.pic" mode="aspectFill" class="pic"></image>
							<view class="talkContent">{{item.talkContent}}</view>
						</view>
					</view>
				</view>
			</view>
			<view class="box-2">
				<view class="flex_col">
					<view class="flex_grow">
						<input type="text" class="talkContent" v-model="talkContent" placeholder="请输入聊天内容" placeholder-style="color:#DDD;"
						 :cursor-spacing="6">
					</view>
					<button class="send" @tap="send">发送</button>
				</view>
			</view>
		</view>
	</div>
</template>
<script>
	/*
 我这里使用的是m3u8流，你们也可以选择其他方式，dplayer官网都有详细介绍。
*/
	let Hls = require('hls.js');
	import DPlayer from 'dplayer';
	import {
		MESSAGE_TYPE
	} from 'vue-baberrage'
	export default {
		name: "Live",
		data() {
			return {
				content: [{
					iconPath: "https://img1.baidu.com/it/u=3229045480,3780302107&fm=26&fmt=auto&gp=0.jpg",
					text: "IPhone12",
					id: "123"
				}],
				msg: [],
				barrageIsShow: true,
				currentId: 0,
				barrageLoop: false,
				barrageList: [],
				websocket: '',
				horizontal: "left",
				vertical: "top",
				lives: "",
				speakSocket: '',
				talkSocket: '',
				talkList: [],
				ajax: {
					rows: 20, //每页数量
					page: 1, //页码
					flag: true, // 请求开关
					loading: true, // 加载中
					loadText: '正在获取消息'
				},
				talkContent: '',
			}
		},
		onLoad(params) {
			this.newWebsocket();
			var id = params.live
			var content = this.content
			this.$http.get('live/goods', {
				live_id: id
			}, {}).then(res => {
				console.log(res.data.data)
				var res = res.data.data
				for (let re of res) {
					var data = {
						iconPath: re.liveGoods.image,
						text: re.liveGoods.goods_name,
						id: re.goods_id
					}
					content.push(data)
				}
				this.content = content
			})
			this.$http.get('live/detail', {
				live_id: id
			}, {}).then(res => {
				console.log(res.data.data)
				this.lives = res.data.data
			})
			// setInterval(()=>{
			// 	//
			// 	this.websocket.send('one');
			// },2000);
		},
		mounted() {
			this.$nextTick(() => {
				this.getHistoryMsg();
			});
			setTimeout(() => {
				this.live();
			}, 2000)
			// this.newWebsocket();
			// this.talkSocket.send('11');
			// setInterval(()=>{
			// this.speakSocket.send('one');
			// },3000);
		},
		onPageScroll(e) {
			if (e.scrollTop < 5) {
				this.getHistoryMsg();
			}
		},
		methods: {
			newWebsocket() {
				var wsServer = 'ws://121.4.90.66:9502';
				var websocket = new WebSocket(wsServer);
				this.speakSocket = websocket;
				websocket.onopen = function(evt) {
					console.log('连接成功');
				}
				var that = this
				websocket.onmessage = function(evt) {
					var data = JSON.parse(evt.data);
					var arr = []
					for (let s of data) {
						var param = {
							msg: s,
							time: Math.round(Math.random() * 10)
						}
						arr.push(param)
					}
					that.msg = arr;
					that.addToList()
				}
				websocket.onclose = function(evt) {
					console.log("服务器拒绝");
				}
				websocket.onerror = function(evt, e) {
					console.log('错误:' + evt.data);
				}
			},
			// 获取历史消息
			getHistoryMsg() {
				if (!this.ajax.flag) {
					return; //
				}
				// 此处用到 ES7 的 async/await 知识，为使代码更加优美。不懂的请自行学习。
				let get = async () => {
					this.hideLoadTips();
					this.ajax.flag = false;
					let data = await this.joinHistoryMsg();
					// console.log('----- 模拟数据格式，供参考 -----');
					// 查看请求返回的数据结构
					// console.log(data);
					// 获取待滚动元素选择器，解决插入数据后，滚动条定位时使用
					let selector = '';
					if (this.ajax.page > 1) {
						// 非第一页，则取历史消息数据的第一条信息元素
						selector = `#msg-${this.talkList[0].id}`;
					} else {
						// 第一页，则取当前消息数据的最后一条信息元素
						selector = `#msg-${data[data.length-1].id}`;
					}
					// 将获取到的消息数据合并到消息数组中
					this.talkList = [...data, ...this.talkList];
					// 数据挂载后执行，不懂的请自行阅读 Vue.js 文档对 Vue.nextTick 函数说明。
					this.$nextTick(() => {
						// 设置当前滚动的位置
						this.setPageScrollTo(selector);

						this.hideLoadTips(true);

						if (data.length < this.ajax.rows) {
							// 当前消息数据条数小于请求要求条数时，则无更多消息，不再允许请求。
							// 可在此处编写无更多消息数据时的逻辑
						} else {
							this.ajax.page++;
							// 延迟 200ms ，以保证设置窗口滚动已完成
							setTimeout(() => {
								this.ajax.flag = true;
							}, 200)
						}

					})
				}
				get();
			},
			// 拼接历史记录消息，正式项目可替换为请求历史记录接口
			joinHistoryMsg() {
				let join = () => {
					let arr = [];
					//通过当前页码及页数，模拟数据内容
					let startIndex = (this.ajax.page - 1) * this.ajax.rows;
					// let endIndex = startIndex + this.ajax.rows;
					let endIndex = 1;
					for (let i = startIndex; i < endIndex; i++) {
						arr.push({
							"id": i, // 消息的ID
							"talkContent": `欢迎来到直播间`, // 消息内容
							"type": Math.random() > 0.5 ? 1 : 0, // 此为消息类别，设 1 为发出去的消息，0 为收到对方的消息,
							"pic": "/static/dianshijun.png" // 头像
						})
					}
					/*
					  颠倒数组中元素的顺序。将最新的数据排在本次接口返回数据的最后面。
					  后端接口按 消息的时间降序查找出当前页的数据后，再将本页数据按消息时间降序排序返回。
					  这是数据的重点，因为页面滚动条和上拉加载历史的问题。
					 */
					arr.reverse();
					return arr;
				}
				// 此处用到 ES6 的 Promise 知识，不懂的请自行学习。
				return new Promise((done, fail) => {
					// 无数据请求接口，由 setTimeout 模拟，正式项目替换为 ajax 即可。
					setTimeout(() => {
						let data = join();
						done(data);
					}, 1500);
				})
			},
			// 设置页面滚动位置
			setPageScrollTo(selector) {
				let view = uni.createSelectorQuery().in(this).select(selector);
				view.boundingClientRect((res) => {
					uni.pageScrollTo({
						scrollTop: res.top - 30, // -30 为多显示出大半个消息的高度，示意上面还有信息。
						duration: 0
					});
				}).exec();
			},
			// 隐藏加载提示
			hideLoadTips(flag) {
				if (flag) {
					this.ajax.loadText = '消息获取成功';
					setTimeout(() => {
						this.ajax.loading = false;
					}, 300);
				} else {
					this.ajax.loading = true;
					this.ajax.loadText = '正在获取消息';
				}
			},
			// 发送信息
			send() {
				//获取当前时间戳毫秒
				let timestamp = new Date().getTime();
				if (!this.talkContent) {
					uni.showToast({
						title: '请输入有效的内容',
						icon: 'none'
					})
					return;
				}
				uni.showLoading({
					title: '正在发送'
				});
				//异步保存弹幕消息
				this.$http.post('live/add/speak', {
					//传递参数 用户id  当前时间戳
					live_id: this.lives.id,
					content: this.talkContent,
					send_time: timestamp,
				}, {}).then(res => {
					console.logres
					if (res.data.code !== 200) {
						uni.showToast({
							title: '您的发言内容不合格',
							image: '/static/image/cuowu.png', //要写根路径，不要写相对路径
							duration: 1500,
						});
					} else {
						this.speakSocket.send(this.talkContent);
					}
				});
				setTimeout(() => {
					uni.hideLoading();
					// 将当前发送信息 添加到消息列表。
					let data = {
						"id": new Date().getTime(),
						"talkContent": this.talkContent,
						"type": 1,
						"pic": "/static/logo.png"
					};
					this.talkList.push(data);
					this.$nextTick(() => {
						// 清空内容框中的内容
						this.talkContent = '';
						uni.pageScrollTo({
							scrollTop: 999999, // 设置一个超大值，以保证滚动条滚动到底部
							duration: 0
						});
					})
				}, 1500);
			},
			bindTextAreaBlur: function(e) {
				console.log(e.detail.value)
			},
			trigger(e) {
				var goods_id = e.item.id
				console.log(goods_id)
				uni.navigateTo({
					url: '/pages/GoodsDetails/GoodsDetails?goods_id=' + goods_id,
					animationType: 'zoom-fade-out',
					animationDuration: 200
				})
			},
			addToList() {
				var data = this.msg
				for (let s of data) {
					this.barrageList.push({
						id: ++this.currentId,
						avatar: "https://img1.baidu.com/it/u=3229045480,3780302107&fm=26&fmt=auto&gp=0.jpg",
						msg: s.msg,
						time: s.time,
						type: MESSAGE_TYPE.NORMAL
					});
				}
			},
			// 直播
			live() {
				var data = this.lives
				const dp = new DPlayer({
					live: true,
					container: document.getElementById('dplayer'),
					video: {
						url: data.pull_url, // 示例地址
						type: 'customHls',
						customType: {
							customHls: function(video, player) {
								const hls = new Hls();
								hls.loadSource(video.src);
								hls.attachMedia(video);
							},
						},
					},
				});
			}
		}
	};
</script>
<style scoped>
	#dplayer {
		width: 100%;
		height: 500px;
	}
</style>
<style lang="scss">
	@import "../../lib/global.scss";
	@import "talk.scss";
</style>
